/***********************************************************
* 
*     File Name:  taskWork.cpp
* 
*        Author:  Algolc
* 
*          mail:  17360224@qq.com
* 
*  Created Time:  Tue 10 Jul 2018 05:56:48 PM CST
* 
***********************************************************/

#include <stdlib.h>
#include <zhelpers.h>

int main() {
    void* context = zmq_ctx_new();

    //用于接受消息的套接字
    void* receiver = zmq_socket(context, ZMQ_PULL);
    zmq_connect(receiver, "tcp://localhost:5557");

    //用于发送消息的套接字
    void* sender = zmq_socket(context, ZMQ_PUSH);
    zmq_connect(sender, "tcp://localhost:5558");

    //永远的处理任务
    while(true) {
        char* rec_str = s_recv(receiver); 
        
        //用于查看器的简易过程指示器
        fflush(stdout);
        printf("%s.", rec_str);

        //不做工作
        s_sleep(atoi(rec_str));
        free(rec_str);

        //发送结果给接受器
        char tmp_str[1] = "";
        s_send(sender, tmp_str);
    }

    zmq_close(receiver);
    zmq_close(sender);
    zmq_ctx_destroy(context);

    return 0;
}
